package com.bfxy.disruptor;

import com.bfxy.entity.TranslatorDataWapper;
import com.lmax.disruptor.WorkHandler;

//netty客户端和服务端消费者的共有基类。netty客户端和服务端消费者是不一样的。
public abstract class MessageConsumer implements WorkHandler<TranslatorDataWapper> {

	protected String consumerId;
	
	public MessageConsumer(String consumerId) {
		this.consumerId = consumerId;
	}

	public String getConsumerId() {
		return consumerId;
	}

	public void setConsumerId(String consumerId) {
		this.consumerId = consumerId;
	}
}
